package indicator;

import com.alibaba.fastjson.JSON;
import org.apache.commons.collections.CollectionUtils;
import org.apache.flink.api.common.serialization.SimpleStringSchema;
import org.apache.flink.api.common.state.MapStateDescriptor;
import org.apache.flink.api.common.typeinfo.BasicTypeInfo;
import org.apache.flink.api.java.typeutils.MapTypeInfo;
import org.apache.flink.streaming.api.datastream.*;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.RichSourceFunction;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer011;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import utils.ImpalaUtil;

import javax.sql.DataSource;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.stream.Collectors;

/**
 * @ClassName RichSourceTest
 * @Deacription TODO
 * @Author wushumin
 * @Date 2021-06-22 8:54
 * @Version 1.0
 **/
public class IndicatorTest {
    public static void main(String[] args) {
        IndicatorCommonUVService uvService = new IndicatorCommonUVService();
        try {
            uvService.process();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}
